package com.company.messagequeue.kafka.consumer;

import com.company.messagequeue.message.CommonMessage;

/**
 * Title: KafkaMessageListener<br>
 * Description: KafkaMessageListener<br>
 * CreateDate:2020年12月04日 19:13
 *
 */
public interface KafkaMessageListener {

  /**
   * Title: 消费者监听方法<br>
   * Description: <br>
   * CreateDate: 2020年12月07日 11:38:30<br>
   *
   * @category 消费者监听方法
   * @param message
   * @return
   * @exception Exception
   */
  public boolean consume(CommonMessage message);
}
